package plus.easydo.easypush.redis;

import com.alibaba.fastjson.JSON;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
import plus.easydo.starter.redis.AbstractMessageHandler;

/**
 * @author laoyu
 * @version 1.0
 * @date 2022/2/22
 */
@Component("Topic1MessageHandler")
public class Topic1MessageHandler extends AbstractMessageHandler<String> {

    private static final Logger logger = LoggerFactory.getLogger(Topic1MessageHandler.class);

    @Override
    public void handleMessage(String message, String topic) {
        logger.info("Topic1MessageHandler: topic={} ,message={}",topic, JSON.toJSONString(message));


    }
}
